package flinkdemo.kafak;

import flinkdemo.kafak.entity.VideoMsg;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

import java.util.List;

public class ImgWindowFaceSink extends RichSinkFunction<List<VideoMsg>> {

    public ImgWindowFaceSink() {}


    @Override
    public void invoke(List<VideoMsg> msgs, Context context) throws Exception {
        for(VideoMsg msg : msgs){
            System.out.println(msg.getMsgId());
            //Gson gson = new Gson();
            //System.out.println(Thread.currentThread().getName()+":"+gson.toJson(msg.getInfos()));
        }
    }
}